import config from '../config'
import dmdb from 'dmdb'
let pool
export async function createDmdbPool() {
  if (!pool) {
    try {
      pool = dmdb.createPool(config.dmdb) // 创建一个包含 10 个连接的连接池
      console.log('DMDB 连接池创建成功！')
    } catch (err) {
      console.error('DMDB 连接池创建失败：', err)
      process.exit(1) // 创建失败则退出应用
    }
  }
  return pool
}
export async function getDmdbPool(): Promise<dmdb.Connection> {
  pool = await dmdb.getConnection(config.dmdb.connectString)
  return pool
}
